# This file is a part of the open-eBackup project.
# This Source Code Form is subject to the terms of the Mozilla Public License, v. 2.0.
# If a copy of the MPL was not distributed with this file, You can obtain one at
# http://mozilla.org/MPL/2.0/.
#
# Copyright (c) [2024] Huawei Technologies Co.,Ltd.
#
# THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND,
# EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT,
# MERCHANTABILITY OR FIT FOR A PARTICULAR PURPOSE.
from unittest.mock import MagicMock, patch


class KafkaProducerMock:
    def produce(self, *args, **kwargs):
        pass

    def flush(self, *args, **kwargs):
        pass


producer_patcher = patch("confluent_kafka.Producer", MagicMock(return_value=KafkaProducerMock()))
producer_patcher.start()
